//package baiguoyuan.kafka.interceptor;
//
//import org.apache.kafka.clients.producer.ProducerInterceptor;
//import org.apache.kafka.clients.producer.ProducerRecord;
//import org.apache.kafka.clients.producer.RecordMetadata;
//
//import java.util.Map;
//
//public class TimeStampPrependerInterceptor implements ProducerInterceptor<String, String>{
//    @Override
//    public void configure(Map<String, ?> configs) {
//
//    }
//    @Override
//    public ProducerRecord onSend(ProducerRecord record) {
//        return new ProducerRecord (
//                record.topic(), record.partition(), record.timestamp(), record.key(), System.currentTimeMillis() + "," + record.value().toString());
//    }
//
//    @Override
//    public void onAcknowledgement(RecordMetadata metadata, Exception exception) {
//
//    }
//
//    @Override
//    public void close() {
//    }
//
//}